Node / markqvist / reticulum-cpp.git / files / src / Interface.cpp

Displaying Raw • Download

#include "Interface.h"

#include "Identity.h"

#include "Transport.h"

using namespace RNS;

using namespace RNS::Type::Interface;

/*virtual*/ inline void Interface::processIncoming(const Bytes& data) {

extreme("Interface::processIncoming: data: " + data.toHex());

assert(_object);

_object->_rxb += data.size();

// CBA TODO implement concept of owner or a callback mechanism for incoming data

//_object->_owner.inbound(data, *this);

Transport::inbound(data, *this);

}

/*virtual*/ inline void Interface::processOutgoing(const Bytes& data) {

extreme("Interface::processOutgoing: data: " + data.toHex());

assert(_object);

_object->_txb += data.size();

}

const Bytes Interface::get_hash() const {

return Identity::full_hash({toString()});

}

void Interface::process_announce_queue() {

/*

if not hasattr(self, "announce_cap"):

self.announce_cap = RNS.Reticulum.ANNOUNCE_CAP

if hasattr(self, "announce_queue"):

try:

now = time.time()

stale = []

for a in self.announce_queue:

if now > a["time"]+RNS.Reticulum.QUEUED_ANNOUNCE_LIFE:

stale.append(a)

for s in stale:

if s in self.announce_queue:

self.announce_queue.remove(s)

if len(self.announce_queue) > 0:

min_hops = min(entry["hops"] for entry in self.announce_queue)

entries = list(filter(lambda e: e["hops"] == min_hops, self.announce_queue))

entries.sort(key=lambda e: e["time"])

selected = entries[0]

now = time.time()

tx_time = (len(selected["raw"])*8) / self.bitrate

wait_time = (tx_time / self.announce_cap)

self.announce_allowed_at = now + wait_time

self.processOutgoing(selected["raw"])

if selected in self.announce_queue:

self.announce_queue.remove(selected)

if len(self.announce_queue) > 0:

timer = threading.Timer(wait_time, self.process_announce_queue)

timer.start()

except Exception as e:

self.announce_queue = []

RNS.log("Error while processing announce queue on "+str(self)+". The contained exception was: "+str(e), RNS.LOG_ERROR)

RNS.log("The announce queue for this interface has been cleared.", RNS.LOG_ERROR)

*/

}